package cn.tonyandmoney.warescanapp.socket

import io.reactivex.Observer
import io.reactivex.disposables.Disposable

/**
 * Created by niantuo on 2018/2/28.
 * 如果要取消，必须得记录那个
 */
class RxWebSocketObserver:Observer<Int> {

    override fun onComplete() {

    }

    override fun onError(e: Throwable) {

    }

    override fun onNext(t: Int) {

    }

    override fun onSubscribe(d: Disposable) {

    }
}